package com.qingcloud.df.executor.queue.subscriber;

import com.qingcloud.df.sdk.component.context.CompInstContext;
import com.qingcloud.df.sdk.component.transport.akka.AkkaTransporter;

import java.util.List;

/**
 * 组件订阅者
 *
 * @author yangfan
 * @date 2022/1/17 14:47
 */
public interface ComponentSubscriber {

    /**
     * 订阅主题
     * @param transporter 组件消息队列
     * @param topics 主题列表
     */
    void subscribe(CompInstContext context , List<String>  topics);

    /**
     * 取消订阅
     */
    void unsubscribe(CompInstContext context ,List<String> topic);


    void remove(Integer jobId,Integer instanceId, String env);
}
